import org.apache.spark.sql.SparkSession

// 创建SparkSession实例
val spark = SparkSession.builder()
  .appName("Basic DataFrame Operations")
  .master("local[*]")
  .getOrCreate()

// 读取sales_data.csv文件到DataFrame中
val salesDF = spark.read.format("csv")
  .option("header", "true")
  .load("path/to/sales_data.csv")

// 检查并展示DataFrame的前5行数据
salesDF.show(5)
